package com.woniuxy.config;

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: 马宇航
 * @do:配置RabbitMqTemplate的confirmCallback的一个回调函数
 * @DateTime: 25/09/01/星期一 15:41
 * @Component: 成都蜗牛学苑
 **/
@Configuration
public class RabbitMQConfig {
    //异步函数
    @Bean
    public RabbitTemplate.ConfirmCallback confirmCallback(){
        return (correlationData, ack, cause) -> {
            if(ack){
                System.out.println(correlationData.getId()+": id信息");
                System.out.println("消息发送成功");
            }else{
                System.out.println("消息未入队的原因:"+cause);
                //通过sse或者socket给客户端发送消费卷没抢到.
            }
        };
    }
}
